package com.soho.core;

import java.util.List;

import com.jfinal.config.Constants;
import com.jfinal.config.Handlers;
import com.jfinal.config.Interceptors;
import com.jfinal.config.JFinalConfig;
import com.jfinal.config.Plugins;
import com.jfinal.config.Routes;
import com.jfinal.kit.Prop;
import com.jfinal.kit.PropKit;
import com.jfinal.plugin.activerecord.ActiveRecordPlugin;
import com.jfinal.plugin.druid.DruidPlugin;
import com.jfinal.server.undertow.UndertowServer;
import com.jfinal.template.Engine;
import com.soho.controller.ApiController;
import com.soho.controller.ApiWebsocket;
import com.soho.helper.QuoteHelper;
import com.soho.model.Symbols;
import com.soho.model._MappingKit;

import online.mtapi.mt4.QuoteEventArgs;
import online.mtapi.mt4.QuoteEventHandler;

/**
 * 本 demo 仅表达最为粗浅的 jfinal 用法，更为有价值的实用的企业级用法
 * 详见 JFinal 俱乐部: http://jfinal.com/club
 * 
 * API 引导式配置
 */
public class CoreConfig extends JFinalConfig {
	
	static Prop p;
	
	/**
	 * 启动入口，运行此 main 方法可以启动项目，此 main 方法可以放置在任意的 Class 类定义中，不一定要放于此
	 */
	public static void main(String[] args) {
		UndertowServer.create(CoreConfig.class).configWeb(builder->{
			builder.addWebSocketEndpoint("com.soho.controller.ApiWebsocket");
		}).start();
		
		
	}
	
	// 系统启动完成后回调
	public void onStart() {
		Mt4 mt4=Mt4.getInstance();
		List<Symbols> symbolList=Symbols.getList();
		symbolList.forEach((item)->{
			mt4.subscribe(item.getSymbol());
		});
		
		QuoteHelper.startListen();
		
	//	CronMain.run();
	}
	 
	
	/**
	 * PropKit.useFirstFound(...) 使用参数中从左到右最先被找到的配置文件
	 * 从左到右依次去找配置，找到则立即加载并立即返回，后续配置将被忽略
	 */
	static void loadConfig() {
		if (p == null) {
			p = PropKit.useFirstFound("demo-config-pro.txt", "demo-config-dev.txt");
		}
	}
	
	/**
	 * 配置常量
	 */
	public void configConstant(Constants me) {
		loadConfig();
		me.setDevMode(p.getBoolean("devMode", false));
	}
	
	/**
	 * 配置路由
	 */
	public void configRoute(Routes me) {
		me.add("/", ApiController.class);
		//获取所有的货币
		me.add("/GetSymbolList", ApiController.class);
		//获取Bar历史数据
		me.add("/QuoteHistory", ApiController.class);
		//开始订阅接收与发送数据
		me.add("/StartListen", ApiController.class);
		//开始监听指定货币
		me.add("/StartListener", ApiController.class);
		//开始移除指定货币的监听
		me.add("/StopListenerSymbol", ApiController.class);
		

		me.add("/OrderMarket", ApiController.class);
		me.add("/OrderCancel", ApiController.class);
		me.add("/OrderPending", ApiController.class);
		
		
	}
	
	public void configEngine(Engine me) {
	}
	
	/**
	 * 配置插件
	 */
	public void configPlugin(Plugins me) {
		// 配置 druid 数据库连接池插件
		DruidPlugin druidPlugin = new DruidPlugin(p.get("jdbcUrl"), p.get("user"), p.get("password").trim());
		me.add(druidPlugin);
		
		
		// 配置ActiveRecord插件
		ActiveRecordPlugin arp = new ActiveRecordPlugin(druidPlugin);
		arp.setShowSql(p.getBoolean("devMode", false));
		me.add(arp);
		// 所有映射在 MappingKit 中自动化搞定
		_MappingKit.mapping(arp);
		
	}
	
	public static DruidPlugin createDruidPlugin() {
		loadConfig();
		
		return new DruidPlugin(p.get("jdbcUrl"), p.get("user"), p.get("password").trim());
	}
	
	/**
	 * 配置全局拦截器
	 */
	public void configInterceptor(Interceptors inv) {
		inv.add(new MyExceptionInterceptor());
	}
	
	
	/**
	 * 配置处理器
	 */
	public void configHandler(Handlers me) {
		
	}
}
